from celery import Celery

"""
broker=存储tasks的仓库   
backend=存储results的仓库 
include=[任务文件们]
"""
broker = 'redis://127.0.0.1:6379/11'
backend = 'redis://127.0.0.1:6379/12'
include = ['celery_task_1.task1', 'celery_task_1.task2']
app = Celery(broker=broker, backend=backend, include=include)

# 启动celery服务的命令：
# 前提：一定要进入celery_task_1所属的文件夹
# celery worker -A celery_task_1 -l info -P eventlet
